package com.lhl.mq.common;

import com.lhl.mq.mqServer.core.BasicProperties;

import java.io.IOException;

@FunctionalInterface
public interface Consumer {

    void handleDelivery(String consumerTag, BasicProperties basicProperties,byte[] body) throws IOException, MqException, ClassNotFoundException;

}
